/**
 * Copyright ©2003~2019年5月29日 szkingdom
 * @author raohj
 * @date 2019年5月29日
 * @file RRocketMQProducer.java
 * @comment : please input your comment to this file
 * @version : input version
 * @modify:
 * 		1、 2019年5月29日 由 raohj 新建文件
 */
package com.ccnu.demojava.mq.rocketmq.topic;

import org.apache.rocketmq.client.exception.MQBrokerException;
import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.common.message.Message;
import org.apache.rocketmq.remoting.exception.RemotingException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * @author raohj
 * @date 2019年5月29日
 * @version 
 * @comment to add your comment
 */
public class RRocketMQPublisher {
	private static final Logger log = LoggerFactory.getLogger(RRocketMQPublisher.class);
	/**
	 * @author raohj
	 * @date 2019年5月29日
	 * @comment add your comment
	 * @param 
	 * @return 
	 * @param args
	 */
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		DefaultMQProducer producer = new DefaultMQProducer("producer_group1");
		producer.setNamesrvAddr("127.0.0.1:9876");
		try {
			producer.start();
			
			for(int i=0; i<10; i++) {
				Message msg = new Message(
						"Topic_test1",
						"request",
						("Hello World" + i).getBytes()
						);
				
				SendResult sr = producer.send(msg, 10000);
			
				Thread.sleep(1000);
			}

		} catch (MQClientException | RemotingException | MQBrokerException | InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		producer.shutdown();
	}

}
